package com.relytosoft.mizar.media.host.emqx;

import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;

/**
 * @author Jierry
 * @version 2022/4/22.
 */
@Component
public class AlarmMqttMessageListener implements com.relytosoft.mizar.media.common.emqx.listener.AlarmMqttMessageListener {

    private static final Logger log = LoggerFactory.getLogger(AlarmMqttMessageListener.class);

    @Override
    public void messageArrived(String topic, MqttMessage message) throws Exception {
        log.info("线程名称：【" + Thread.currentThread().getName() + "】"+"接收的主题：" + topic);
    }
}
